// 连接数据库
var mysql = require('mysql')
var config = require('../config')

// 创建连接池
var pool = mysql.createPool(config.db)
// 封装数据库操作
module.exports.dbSql = function (sql, param, callback) {
  pool.getConnection((err, conn) => {
    if (err) {
      return callback('连接失败' +  err)
    }
    conn.query(sql, param, (err, results) => {
      if (err) {
        return callback('执行失败:' + err, null);
      }
      callback(err, results);
    })
    conn.release();
  })
}